package cn.dglydrpy.study.ssm.common.kafka.serializer;

import net.sf.json.JSONObject;
import org.apache.kafka.common.serialization.Serializer;

import java.util.Map;
/**
 * 生产环境上序列化和反序列化的解决方案
1.JSON本质上等同于自定义的序列化器和反序列化器
2.使用Apache Arvo
 * @author hasee
 *
 */
public class JsonSerializer implements Serializer<JSONObject> {
    @Override
    public void configure(Map<String, ?> map, boolean b) {

    }

    @Override
    public byte[] serialize(String s, JSONObject jsonObject) {
        try {
           return jsonObject.toString().getBytes("UTF-8");
        } catch (Exception e){
            e.printStackTrace();
            return null;
        }
    }

    @Override
    public void close() {

    }
}
